package com.kancy.delay.queue.redis.handler;

import com.kancy.delay.queue.redis.message.DelayMessage;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 * <p>
 * EmptyDelayQueueMessageHandler
 * <p>
 *
 * @author: kancy
 * @date: 2020/3/4 22:15
 **/
public class EmptyDelayQueueMessageHandler implements DelayQueueMessageHandler{
    private static final Logger log = LoggerFactory.getLogger(EmptyDelayQueueMessageHandler.class);

    /**
     * 处理延迟消息
     *
     * @param delayMessage
     */
    @Override
    public void process(DelayMessage delayMessage) {
        log.info("处理消息：{}", delayMessage);
    }
}
